package com.mashibing.rocketmq;



import java.util.ArrayList;

import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendCallback;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;


/**
 * 消息过滤
 */
public class Producer4 {
    public static void main(String[] args) throws Exception{
        DefaultMQProducer producer = new DefaultMQProducer("xoxogp");

        // 设置nameserver地址
        producer.setNamesrvAddr("192.168.150.113:9876");
        producer.start();

        // tag 是用来过滤消息，或理解成消息分组
        //一个topic里可以分成多个组，可以按照业务线来划分。。
        //key主要是用来找这条消息的，运维的时候，用来找消息。。key不是唯一的，只是拿来查而已。比如projectId
        //
        Message message = new Message("myTopic002", "TAG-A","KEY-xx","xxooxx".getBytes());

        // cap里，，p 网络不确定
        producer.send(message);

        producer.shutdown();
        System.out.println("已经停机");
    }

}
